/** 
* @version:1.0.1
* @Description: （对类进行功能描述）
* @author: yangdechao
* @date: datedate 2021年11月12日 下午4:26:18
*/
package cn.com.guage.flink.source;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import cn.com.guage.flink.domain.SensorReading;

/**
 * @version:1.0.1
 * @Description: （对类进行功能描述）
 * @author: yangdechao
 * @date: datedate 2021年11月12日 下午4:26:18
 */
public class ConsumerFromSensorSource {
	public static void main(String[] args) throws Exception {
		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		env.setParallelism(1);
	
		DataStream<SensorReading> stream = env.addSource(new SensorSource());
		stream.print();
		env.execute();
	}
}
